package com.beiding.dbrequest.common;


import io.reactivex.Observable;
import lombok.Getter;



/**
 * 消息类型封装一个Promise,用于接收异步结果
 * 用于control返回Promise
 */
public class ObservableMessage extends Message {

    @Getter
    private Observable observable;

    public ObservableMessage(Observable observable) {
        this.observable = observable;
    }
}
